package com.telit.communicate.constant;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicBoolean;


/**
 * @author zhouyu
 * @description 变量
 */
public class CommunicateVariable {

    /**
     * 能否继续接收数据
     */
    public static ConcurrentHashMap<String, Boolean> enableReceiveMsg = new ConcurrentHashMap<>(
            SystemName.getFields().length * MsgSource.getFields().length);;

    /**
     * 线程池句柄缓存
     */
    public static ConcurrentHashMap<String, ExecutorService> threadPoolHandler = new ConcurrentHashMap<>(SystemName.getFields().length * MsgSource.getFields().length);

    /**
     * 线程绑定变量句柄
     */
    public static ConcurrentHashMap<String, Boolean> threadHandler = new ConcurrentHashMap<>(SystemName.getFields().length * MsgSource.getFields().length);

    /**
     * 客户端是否注册成功
     */
    public static final AtomicBoolean registerSuccess = new AtomicBoolean(false);
}
